package com.clj.rocketmq_example.mq;

import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext;
import org.apache.rocketmq.common.message.MessageExt;
import com.clj.rocketmq_example.enums.MqAction;

/**
 * 普通消息监听
 * 
 * @author C117
 *
 */
public interface MessageListener {
	/**
	 * mq 消费接口
	 * 
	 * @param var1
	 * @param context
	 * @return
	 */
	MqAction consume(MessageExt var1, ConsumeConcurrentlyContext context);
}
